package com.qiyu.mq.core.consumer;

import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;

/**
 * @author  idea
 * @version V1.0
 * @date 2020/8/10
 */
public interface ConcurrentlyConsumer<T> {

    ConsumeConcurrentlyStatus consume(T t);

}
